#include "App_Mqtt.h"
#include "log/log.h"
#include "unistd.h"

// 回调函数
int receive_callback(char *json)
{
    log_debug("处理远程接收到的消息为%s", json);
}

int main()
{
    // 初始化
    App_Mqtt_Init();
    // 设置回调函数
    App_Mqtt_RegisterRecvCallBack(receive_callback);
    //发送消息
    App_Mqtt_Send("{\"connect_type\":1,\"id\":\"5859\",\"msg\":\"61626364\"}");
    // 等待接受消息处理
    sleep(100);
    // 关闭mqtt连接
    App_Mqtt_Close();
    return 0;
}